package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.pojo.Point0F39;
import com.navinfo.tripanalysis.offline.pojo.LoadDataParam;
import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;

/**
 * 载入0F39故障数据服务
 * @author hmc
 */
public interface LoadPoint0F39Service extends  Serializable{
    JavaRDD<Point0F39> load(SparkSession spark, JavaSparkContext jsc, LoadDataParam param);
}
